package org.apache.flink.runtime.messages;

import org.apache.flink.api.common.ConsumerID;
import org.apache.flink.util.ERException;

/** Exception indicating that we could not find a elastic-resource consumer with the given consumer ID. */
public class ERConsumerNotFoundException extends ERException {

    private static final long serialVersionUID = 2294698055059659025L;

    public ERConsumerNotFoundException(ConsumerID consumerId) {
        super("Could not find elastic resource consumer (" + consumerId + ')');
    }
}
